﻿namespace DataIntegration.Messaging.Consumer
{
    using System;
    using Utils.Lifecycle;

    public interface IConsumer : ILifecycle
    {
        void Consume(string topic);

        void ConsumeDurable(string topic);

        event Action<string, string> MessageReceived;
    }
}